package com.gome.han.bigdata.mr._002_01_wordcount;

import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Reducer;

import java.io.IOException;

/**
* @author hanpeng
* @version 创建时间：2020年11月21日 下午3:54:40
* @ClassName 类名称
* @Description 类描述
*/
public class WordcountReducer extends Reducer<Text, IntWritable, Text, IntWritable>{
	IntWritable v = new IntWritable();
	@Override
	protected void reduce(Text key, Iterable<IntWritable> values,
			Context context) throws IOException, InterruptedException {
		//Iterable<IntWritable> values 表示key 相同的value的集合
//		atguigu,1
//		atguigu,1
		int sum = 0;
		
		// 1 累加求和
		for (IntWritable value : values) {
			
			sum += value.get();
		}

		v.set(sum);
		
		// 2 写出 atguigu 2
		context.write(key, v);
	}
}
